package com.stream.demo;

import org.springframework.messaging.support.MessageBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ResponseBody;


@Controller
public class TestController {

    @Autowired
    private MyProcess myProcess;

    @GetMapping("test")
    @ResponseBody
    public void test() {
        /**
         * input1Changel和input3Changel分别属于 group-a1和 group-a3且二者所指向的通道是指向wdtest1_，因此使用output1Chanel发送消息的时候
         * ，input1Changel和input3Changel会分别消费output1Chanel的消息。
         * input2Changel属于group-a1且通道是指向wdtest2_，因此使用output2Chanel发送消息的时候
         * input2Changel会消费output2Chanel的消息
         */
        myProcess.output1Chanel().send(MessageBuilder.withPayload("1").setHeader("type","foo").build());
        myProcess.output2Chanel().send(MessageBuilder.withPayload("2").setHeader("type","foo").build());
    }



}
